package org.javaboy.stream_old_version.msg;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface MyChannel {
    // 输出通道，将来在这个通道上发送消息
    String OUTPUT = "javaboy_output";
    // 输入通道，将来在这个通道上消费消息
    String INPUT = "javaboy_input";

    String output2 = "";
    String input2 = "";

    @Output(OUTPUT)
    MessageChannel output();

    @Input(INPUT)
    SubscribableChannel input();
}
